google.golang.org/grpc.clientStream.cc (field)
15 uses
google.golang.org/grpc (current package)
stream.go#L331: cc: cc,
stream.go#L378: Authority: cs.cc.authority,
stream.go#L414: if err := cs.cc.ctx.Err(); err != nil {
stream.go#L421: shs := cs.cc.dopts.copts.StatsHandlers
stream.go#L451: if cs.cc.parsedTarget.URL.Scheme == internal.GRPCResolverSchemeExtraMetadata {
stream.go#L463: decompressorV0: cs.cc.dopts.dc,
stream.go#L473: pick, err := cs.cc.pickerWrapper.pick(a.ctx, cs.callInfo.failFast, pickInfo)
stream.go#L532: a.parser = &parser{r: s, bufferPool: a.cs.cc.dopts.copts.BufferPool}
stream.go#L541: cc *ClientConn
stream.go#L667: if cs.cc.dopts.disableRetry {
stream.go#L684: channelz.Infof(logger, cs.cc.channelz, "Server retry pushback specified to abort (%q).", sps[0])
stream.go#L690: channelz.Warningf(logger, cs.cc.channelz, "Server retry pushback specified multiple values (%q); not retrying.", sps)
stream.go#L919: hdr, data, payload, pf, err := prepareMsg(m, cs.codec, cs.compressorV0, cs.compressorV1, cs.cc.dopts.copts.BufferPool)
stream.go#L1085: cs.cc.incrCallsFailed()
stream.go#L1087: cs.cc.incrCallsSucceeded()